package com.zhu.config;

/**
 * 集群参数 配资
 */
public class ClusterParametersConfig {

    public static final String  KAFKA_BOOTSTRAP_SERVER = "hadoop102:9092,hadoop103:9092,hadoop104:9092";

    public static final String KAFKA_BASE_DB_TOPIC = "topic_db";

    public static final String KAFKA_BASE_LOG_TOPIC = "topic_log";

    public static final String HDFS_CHECKPOINT_FILE_DIR ="hdfs://hadoop102:8020/flink/ck";


}
